#include "../mqserver/mq_connection.hpp"

int main()
{
    castlemq::ConnectionManager::ptr cmp= std::make_shared<castlemq::ConnectionManager>();
    auto it =muduo::net::TcpConnectionPtr();
    cmp->newConnection(it,castlemq::ProtobufCodecPtr(),castlemq::ConsumerManager::ptr(),
        std::make_shared<castlemq::VirtualHost>("host1","./data/host1/message","./data/host1/host1.db"),threadpool::ptr());
    
    auto ret = cmp->getConnection(it);
    cmp->deleteConnection(it);
    return 0;
}